package com.olive.service;

import java.util.function.Consumer;

import com.olive.dto.MessageDTO;

public class CustomConsumer implements Consumer<MessageDTO> {

	@Override
	public void accept(MessageDTO message) {
		 System.out.println("接收广播消息：" + message.getPayload());
	}

}
